<?php
	set_time_limit(0);
	include_once('/var/www/sinvest/classes/util.controler.php');
	
	$PATH_TEMP = '/bkp/temp/';
	$maiorData = $pConexao->leiaValor($pConexao->execute("SELECT to_char(data,'YYYYMMDD') FROM (SELECT DISTINCT B.data FROM papeis B ORDER BY B.data DESC OFFSET 0 LIMIT 1) as A"));
	if ($maiorData==date('Ymd')){
		echo "[DATA JA PROCESSADA]\n";
		die;
	}
	if (date('N')>5){
		echo "[FIM DE SEMANA]\n";
		die;
	}

	execut('wget -O '.$PATH_TEMP.'CH20XX.zip http://www.bmfbovespa.com.br/InstDados/SerHist/COTAHIST_A2012.zip');
	execut('rm '.$PATH_TEMP.'COTAHIST_A2012.TXT');
	execut('unzip -u '.$PATH_TEMP.'CH20XX.zip -d '.$PATH_TEMP);
	execut('tail -n 5000 '.$PATH_TEMP.'COTAHIST_A2012.TXT > '.$PATH_TEMP.'acoesRecorte.TXT');
	 
	$linTeste = execut('tail -n 2 /bkp/temp/acoesRecorte.TXT');
	$dataArquivo = substr($linTeste,2,8);
	if ($dataArquivo==$maiorData) {
		echo "[ARQUIVO JA PROCESSADO]\n";
		die;
	}

	$file = @fopen($PATH_TEMP.'acoesRecorte.TXT', 'r');
	
	if (!$file)
		die();
/*	$pConexao->execute("DELETE FROM papeis");
	$pConexao->execute("ALTER SEQUENCE papeis_id_seq RESTART WITH 1");*/
	$start = 0;
	
	while (!feof($file)) {
		$i++;
		$linha = fgets($file);
		$tpreg = substr($linha,0,2);
		$data = substr($linha,2,8);
		//TESTE DA DATA
		if (!($data>$maiorData && $tpreg=='01'))
			continue;
		//PROCESSAMENTO DO REGISTRO
		$tpmercado = substr($linha,24,3);
		if ($tpmercado=='010' && $tpreg=='01') {
			$s++;
			$codneg = trim(substr($linha,12,12));
			$empresa = substr($linha,27,15);
			$preco_fech = substr($linha,108,13);
			$quant = substr($linha,152,18);
			$negoc = substr($linha,147,5);
			$volume = substr($linha,170,18);
			$pConexao->execute("INSERT INTO papeis (codneg,empresa,preco_ultimo,quant,negoc,volume,data)
				VALUES ('$codneg','$empresa',$preco_fech,$quant,$negoc,$volume,'$data')");
		}
		//echo "$dataOld === $data == $start == $empresa<br />";
	}
	fclose($file);
	echo "[$s]$i - PRONTO!\n";

function execut($comando){
	return shell_exec($comando); 
}

?>
